package db

import (
	"context"

	"go.mongodb.org/mongo-driver/mongo"
	"go.mongodb.org/mongo-driver/mongo/options"
)

var (
	mongodb *mongo.Client
)

func InitMongodb(host string) {
	var err error
	clientOptions := options.Client().ApplyURI(host)
	// 连接到MongoDB
	mongodb, err = mongo.Connect(context.TODO(), clientOptions)
	if err != nil {
		panic(err)
	}
	// 检查连接
	err = mongodb.Ping(context.TODO(), nil)
	if err != nil {
		panic(err)
	}
}

func Mongodb() *mongo.Client {
	return mongodb
}

func MongodbInsert(collectionName string, s ...map[string]interface{}) {
	// var err error
	// collection := mongodb.Database(g.DatabaseName).Collection(collectionName)
	// for _, val := range s {
	// }
	// if err != nil {
	// 	log.Logrus().Fatal(err)
	// }
}
